package com.captjack.bigdata.flume;

import org.apache.flume.Context;
import org.apache.flume.Event;
import org.apache.flume.conf.ComponentConfiguration;
import org.apache.flume.sink.hbase.HbaseEventSerializer;
import org.apache.hadoop.hbase.client.Increment;
import org.apache.hadoop.hbase.client.Row;

import java.util.List;

/**
 * 自定义hbase-sink
 *
 * @author Jack Sparrow
 * @version 1.0.0
 * @date 2018/7/18 23:20
 * package com.captjack.bigdata.flume
 */
public class CustomizeHbaseSink implements HbaseEventSerializer {

    @Override
    public void initialize(Event event, byte[] bytes) {

    }

    @Override
    public List<Row> getActions() {
        return null;
    }

    @Override
    public List<Increment> getIncrements() {
        return null;
    }

    @Override
    public void close() {

    }

    @Override
    public void configure(Context context) {

    }

    @Override
    public void configure(ComponentConfiguration componentConfiguration) {

    }

}
